package main



const VERSION "1.0"

var db *leveldb.DB
var defaultMaxqueue, keepalive, cpu, cacheSize, writeBuffer *int
var ip, port, defaultAuth, dbPath *string
var verbose *bool

func httpmqReadMatedata(name string) []string {
    maxqueue := name + ".maxqueue"
    data1, _ := db.Get([]byte(maxqueue), nil)
    if len(data1) == 0 {
        data1 = []byte(strconv.Itoa(*defaultMaxqueue))
    }
    
}

func main() {
    runtime.GOMAXPROCS(*cpu)
    sync := &opt.WriteOptions{Sync:true}
    putnamechan := make(chan string, 100)
    putposchan := make(chan string, 100)
    getnamechan := make(chan string, 100)
    getposchan := make(chan string, 100)
    
    go func(chan string, chan string) {
        for {
            name := <-putnamechan
            putpos := httpmqNowPutpos(name)
            putposchan <- putpos
        }
    }(putnamechan, puposchan)

    go func(chan string, chan string) {
        for {
            name := <-getnamechan
            getpos := httpmqNowGetpos(name)
            getposchan <- getpos 
        }
    }(getnamechan, getposchan)

    m := func(ctx ( fasthttp.RequestCtx) {
         :wq
    }

}







